//package com.gate.ws.spring.config;
//
//import com.gate.ws.spring.rocketmq.consumer.DownBatchMsgConsumer;
//import org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//import static com.nami.basic.constants.DownTopicConst.FLUSH_MORE_CONSUMER_GROUP;
//import static com.nami.basic.constants.DownTopicConst.FLUSH_MORE_TOPIC;
//
//@Configuration
//public class ConsumerMqConfig {
//
//    @Value("${rocketmq.name-server}")
//    private String nameServer;
//
//
//    @Value("${nami.mqTags}")
//    private String tags;
//
//    @Bean
//    public DefaultRocketMQListenerContainer downBatchMsgConsumerContainer(DownBatchMsgConsumer consumer) {
//        DefaultRocketMQListenerContainer container = new DefaultRocketMQListenerContainer();
//        container.setTopic(FLUSH_MORE_TOPIC);
//        container.setConsumerGroup(FLUSH_MORE_CONSUMER_GROUP);
//        container.setSelectorExpression(tags);
//        container.setRocketMQListener(consumer);
//
//        container.setNameServer(nameServer);
//        // 可以设置其他配置，如nameServer、accessKey、secretKey等
//        return container;
//    }
//
////    @Bean
////    public RocketMQListenerContainer flushOneListener(DownOneMsgConsumer consumer) {
////        DefaultRocketMQListenerContainer container = new DefaultRocketMQListenerContainer();
////        container.setTopic(FLUSH_ONE_TOPIC);
////        container.setConsumerGroup(FLUSH_ONE_CONSUMER_GROUP);
////        container.setSelectorExpression(tags);
////        container.setRocketMQListener(consumer);
////
////        container.setNameServer(nameServer);
////        // 可以设置其他配置，如nameServer、accessKey、secretKey等
////        return container;
////    }
//
//
//}
